package com.gientech.spring.mq;

import com.ctrip.framework.apollo.spring.annotation.EnableApolloConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

@EnableBinding(MessageSink.class)
@Slf4j
@EnableApolloConfig
public class MessageConsumer {

    @StreamListener(MessageSink.MESSAGE_INPUT)
    public void onReceive(String shopJson) {
        log.info("my receive message = {}",shopJson);
    }
}
